package org.alex.mqtt.common.bus;


import org.alex.mqtt.common.bus.event.GatewayListener;
import org.alex.mqtt.common.bus.model.ClusterEvent;

/**
 * 集群事件管理器
 */
public interface ClusterEventManager {

    void sendEvent(ClusterEvent clusterEvent);

    void registerEventListener(GatewayListener listener);

    void start();

    void shutdown();
}
